spark code optimization